//1.引入express框架 
const express = require("express");
const cors = require("cors");
const db = require("./../libs/DBHelper");
const md5 = require("md5");
const fs = require("fs");

//2.创建保安大爷    /login  /Login
const aipRouter = express.Router(/*路径的严格相等的参数*/);
//cors 安全级别很低了,要么使用 webpack proxy代理 ,可以不用跨域
aipRouter.use("*", cors(), function (reuqest, resposne, next) {
    resposne.setHeader("Content-Type", "application/json;charset=utf-8");
    //设置跨域
    // resposne.setHeader("Access-Control-Allow-Origin", "*");
    next();
})
//3.给保安大爷 介绍活
aipRouter.post("/reg", async function (request, response, next) {
    //1.得到前端的数据
    let users = request.body;
    //2.得到数据库对象.进行插入
    let sql = "INSERT INTO `userinfo` (`u_pwd`,`u_tel`,`u_command`)VALUE(?,?,?,?);";
    let parmas = [
        md5(users.upwd),//加密
        users.utel,
        users.ucommand
    ];
    console.log(parmas);

    try {
        //有可能出错误的地方  有网络连接的地方,建议使用 try..catch , 数据库连接,ajax请求..
        let res = await db.executeAsync(sql, parmas);

        if (res && res.affectedRows == 1) {
            response.json({ msg: "注册成功", "status": 200 })
        } else {
            response.json({ msg: "注册失败", "status": -s200 })
        }

    } catch (error) {
        //有错误就指向 catch
        response.json({ msg: "注册异常", info: error });
    } finally {
        //不管是否有错,都会执行 finally
    }
})

// //3.给保安大爷 介绍活
// aipRouter.post("/login", async function (request, response, next) {

//     //1.得到前端的数据
//     let users = request.body;

//     //2.得到数据库对象.进行插入
//     let sql = "SELECT `u_Id`,`u_Name`,`u_Phone`,`u_Email`,`u_Avatar` FROM `userinfo` WHERE u_Name=? AND u_pwd=? AND u_status=1;";
//     let parmas = [
//         users.uname,
//         md5(users.upwd)
//     ];


//     try {
//         //有可能出错误的地方  有网络连接的地方,建议使用 try..catch , 数据库连接,ajax请求..
//         let res = await db.executeAsync(sql, parmas);

//         if (res && res.length >= 1) {
//             response.json({ msg: "登录成功", "status": 200, data: res })
//         } else {
//             response.json({ msg: "登录失败", "status": 0200 })
//         }

//     } catch (error) {
//         //有错误就指向 catch
//         response.json({ msg: "录异常", info: error });
//     } finally {
//         //不管是否有错,都会执行 finally
//     }
// })

// aipRouter.post("/addCart", async function (request, response, next) {
//     let data = request.body;
//     // mainImg: "images/3-1.jpg"
//     // num: 7
//     // p_id: 1
//     // p_name: "无敌的iphone"
//     // p_price: 998
//     // total: 6986
//     // uId: 4

//     let querySql = "SELECT*FROM cartlist WHERE u_id=? AND p_id=? AND c_status=1 ;"
//     let parmasQuery = [data.uId, data.p_id];

//     let queryList = await db.executeAsync(querySql, parmasQuery);

//     if (queryList.length >= 1) {

//         let updateSql = "UPDATE cartlist SET c_num=c_num+? , c_total=c_num*c_price  WHERE u_id=? AND p_id=? AND c_status=1;";
//         let updatePrams = [data.num, data.uId, data.p_id];

//         try {
//             let res = await db.executeAsync(updateSql, updatePrams);

//             if (res && res.affectedRows >= 1) {
//                 response.json({ msg: "加入成功u", status: 200 })
//             } else {
//                 response.json({ msg: "加入失败u", status: -200 })
//             }
//         } catch (error) {
//             response.json({ msg: "加入异常u", error });
//         }



//     } else {


//         let insertSQL = "INSERT INTO `cartlist` (`c_Name`,`c_price`,`c_num`,`c_total`,`c_img`,`u_Id`,p_id) VALUES (?,?,?,?,?,?,?);";

//         let paramsInert = [data.p_name, data.p_price, data.num, data.total, data.mainImg, data.uId, data.p_id];

//         try {
//             let res = await db.executeAsync(insertSQL, paramsInert);
//             if (res && res.affectedRows >= 1) {
//                 response.json({ msg: "加入成功i", status: 200 })
//             } else {
//                 response.json({ msg: "加入失败i", status: -200 })
//             }
//         } catch (error) {
//             response.json({ msg: "加入异常i", error });
//         }
//     }

// })

// //加载购物车
// aipRouter.get("/cart", async function (request, response, next) {
//     let uid = request.query.uid;

//     let sql = "SELECT * FROM cartlist WHERE  c_status=1 AND u_id=?;";
//     let params = [uid];

//     try {

//         let res = await db.executeAsync(sql, params);

//         let result = res.length >= 1 ? { msg: "查询成功", "status": 200, data: res } : { msg: "查询失败", "status": -200 }

//         response.json(result);
//     } catch (err) {

//     }
// })

// //修改数量
// aipRouter.post("/updateCart", async function (request, response, next) {

//     let data = request.body;
//     let sql = "UPDATE cartlist SET c_num=? , c_total=c_num*c_price  WHERE c_Id=? AND c_status=1;";
//     let params = [data.cnum, data.cid];

//     try {
//         let res = await db.executeAsync(sql, params);
//         if (res && res.affectedRows >= 1) {
//             response.json({ msg: "修改成功", status: 200 })
//         } else {
//             response.json({ msg: "修改失败", status: -200 })
//         }
//     } catch (err) {
//         response.json({ msg: "修改异常", info: err });
//     }

// })


// //删除 软删除
// aipRouter.post("/deleteCart", async function (request, response, next) {
//     let cid = request.body.cid;

//     let sql = "UPDATE cartlist SET c_status=0 WHERE c_Id=? AND c_status=1;";
//     let params = [cid];

//     try {
//         let res = await db.executeAsync(sql, params);
//         if (res && res.affectedRows == 1) {
//             response.json({ msg: "删除成功", status: 200 })
//         } else {
//             response.json({ msg: "删除失败", status: -200 })
//         }
//     } catch (err) {
//         response.json({ msg: "删除异常", info: err });
//     }
// })







// aipRouter.get("/list", function (request, response, next) {

//     response.json(JSON.parse(fs.readFileSync("./data/production.json").toString()));
// })

// //动态路由 :pid  + params
// aipRouter.get("/info/:pid", function (request, response, next) {

//     console.log(request.params);
//     let pid = request.params.pid;

//     let res = JSON.parse(fs.readFileSync("./data/production.json").toString()).filter(function (el) {
//         return el.p_id == pid;
//     })

//     response.json(res);
// })







module.exports = aipRouter;
